package com.ldn.server.queue.covert;

import com.ldn.common.basic.dispose.bo.MqttRocketmqBo;
import jakarta.annotation.PostConstruct;
import org.springframework.stereotype.Component;

/**
 * @author 李大牛家的牛 (scafel@163.com)
 * @product serverless
 * @className MqttEquipmentCovert
 * @createDate 2025/3/7 - 13:27
 * @description ToDo...
 **/
@Component
public class MqttEquipmentCovert implements MqttBasicCovert {

    // 维护一个本类的静态变量 方便使用相关注入属性
    private static MqttEquipmentCovert covert;

    @PostConstruct
    public void init() {
        covert = this;
    }

    @Override
    public void subscribeValidHandler(MqttRocketmqBo payload) {

    }

    @Override
    public void publishValidHandler(MqttRocketmqBo payload) {

    }

    @Override
    public void unsubscribeHandler(MqttRocketmqBo payload) {

    }

    @Override
    public void subscribeHandler(MqttRocketmqBo payload) {

    }

    @Override
    public void authenticateHandler(MqttRocketmqBo payload) {

    }

    @Override
    public void offlineHandler(MqttRocketmqBo payload) {

    }

    @Override
    public void onlineHandler(MqttRocketmqBo payload) {

    }

    @Override
    public void messageHandler(MqttRocketmqBo payload) {

    }
}
